package com.zysd.collection.scheduler.service.amqp;

import com.lensyn.collect.meters.store.MetersMessage;
import com.zysd.collection.scheduler.entity.Terminal;

/**
 * 消息推送接口
 *
 * @author liuht
 */
public interface AmqpClientService{

    /**
     * 推送消息
     *  @param terminal 集中器
     * @param msg 消息对象
     */
    void publish(Terminal terminal, MetersMessage msg);
}
